package org.ws.task.item;

import org.ws.task.exception.ItemProcessException;
import org.ws.task.model.TaskItem;

import java.util.Collection;

/**
 * Push任务处理
 * @param <T>
 */
public interface ItemWorkerProcessor<T> {

    /**
     * 自动处理push的任务
     * @param items
     */
    void process(Collection<TaskItem<T>> items)throws ItemProcessException;

}
